Platform Explorer / Nuxeo Platform 11.4

Extension point streamProcessor

Contribution Descriptors

  • Class: org.nuxeo.runtime.stream.StreamProcessorDescriptor

Existing Contributions

Contributions are presented in the same order as the registration order on this extension point. This order is displayed before the contribution name, in brackets.

  • nuxeo-runtime-stream-11.4.42.jar /OSGI-INF/stream-service.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.runtime.stream.StreamMetricsProcessor" enabled="true" name="metrics">
          <policy continueOnFailure="false" delay="1s" maxDelay="10s" maxRetries="5" name="default"/>
          <stream codec="avro" name="input/null" partitions="1"/>
          <computation concurrency="1" name="stream/metrics"/>
        </streamProcessor>
      </extension>
  • nuxeo-core-11.4.42.jar /OSGI-INF/retention-and-hold-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.core.security.RetentionExpiredAction" defaultConcurrency="1" defaultPartitions="1" name="retentionExpired">
          <!-- continue on failure, because failure to expire retention doesn't give us an inconsistent state -->
          <policy continueOnFailure="true" delay="1s" maxDelay="60s" maxRetries="20" name="default"/>
        </streamProcessor>
      </extension>
  • nuxeo-core-11.4.42.jar /OSGI-INF/deletion-action-config.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.core.action.DeletionAction" defaultConcurrency="2" defaultPartitions="2" name="deletion">
          <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
      </extension>
  • nuxeo-platform-csv-export-11.4.42.jar /OSGI-INF/csv-export-config.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <!-- CSV exporter processor -->
        <streamProcessor class="org.nuxeo.ecm.platform.csv.export.action.CSVExportAction" defaultConcurrency="2" defaultPartitions="2" name="csvExport">
          <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
          <option name="produceImmediate">false</option>
        </streamProcessor>
      </extension>
  • nuxeo-platform-imaging-core-11.4.42.jar /OSGI-INF/imaging-bulk-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.platform.picture.recompute.RecomputeViewsAction" defaultConcurrency="2" defaultPartitions="6" name="recomputeViews">
          <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
      </extension>
  • nuxeo-platform-audit-core-11.4.42.jar /OSGI-INF/nxaudit-service.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.platform.audit.impl.StreamAuditWriter" defaultCodec="avro" defaultConcurrency="1" defaultPartitions="1" enabled="true" name="auditWriter">
          <policy batchCapacity="25" batchThreshold="500ms" continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="20" name="default"/>
        </streamProcessor>
      </extension>
  • nuxeo-core-bulk-11.4.42.jar /OSGI-INF/bulk-config.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.core.bulk.BulkServiceProcessor" defaultCodec="avro" defaultConcurrency="1" defaultExternal="true" defaultPartitions="1" name="bulkServiceProcessor" start="false">
          <stream external="false" name="bulk/command"/>
          <stream external="false" name="bulk/status"/>
          <stream external="false" name="bulk/done"/>
          <policy continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="0" name="bulk/scroller"/>
          <policy continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="20" name="bulk/status"/>
          <computation concurrency="2" name="bulk/scroller"/>
          <computation concurrency="1" name="bulk/status"/>
        </streamProcessor>
      </extension>
  • nuxeo-core-bulk-11.4.42.jar /OSGI-INF/bulk-config.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <!-- SetProperty processor -->
        <streamProcessor class="org.nuxeo.ecm.core.bulk.action.SetPropertiesAction" defaultConcurrency="2" defaultPartitions="2" name="setProperties">
          <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
    
        <!-- SetSystemProperty processor -->
        <streamProcessor class="org.nuxeo.ecm.core.bulk.action.SetSystemPropertiesAction" defaultConcurrency="2" defaultPartitions="2" name="setSystemProperties">
          <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
    
        <!-- RemoveProxy processor -->
        <streamProcessor class="org.nuxeo.ecm.core.bulk.action.RemoveProxyAction" defaultConcurrency="2" defaultPartitions="2" name="removeProxy">
          <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
    
        <!-- Trash processor -->
        <streamProcessor class="org.nuxeo.ecm.core.bulk.action.TrashAction" defaultConcurrency="1" defaultPartitions="1" name="trash">
          <policy continueOnFailure="false" delay="500ms" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
    
      </extension>
  • nuxeo-automation-features-11.4.42.jar /OSGI-INF/bulk-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.automation.core.operations.services.bulk.AutomationBulkAction" defaultConcurrency="2" defaultPartitions="2" name="automation">
          <policy continueOnFailure="true" delay="1s" maxRetries="3" name="default"/>
        </streamProcessor>
      </extension>
  • nuxeo-elasticsearch-core-11.4.42.jar /OSGI-INF/bulk-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.elasticsearch.bulk.IndexAction" defaultConcurrency="2" defaultPartitions="4" enabled="true" name="indexAction">
          <policy continueOnFailure="false" delay="1s" maxDelay="60s" maxRetries="20" name="default"/>
          <!-- concurrency to build indexing requests -->
          <computation concurrency="2" name="bulk/index"/>
          <!-- concurrency to execute indexing requests -->
          <computation concurrency="2" name="bulk/bulkIndex"/>
          <computation concurrency="1" name="bulk/indexCompletion"/>
          <!-- optimal size of the elasticsearch bulk request -->
          <option name="esBulkSizeBytes">5242880</option>
          <!-- max number of actions in the elasticsearch bulk request -->
          <option name="esBulkActions">1000</option>
          <!-- flush elasticsearch bulk request interval -->
          <option name="flushIntervalSeconds">5</option>
        </streamProcessor>
    
      </extension>
  • nuxeo-thumbnail-11.4.42.jar /OSGI-INF/thumbnail-bulk-contrib.xml
    <extension point="streamProcessor" target="org.nuxeo.runtime.stream.service">
        <streamProcessor class="org.nuxeo.ecm.platform.thumbnail.action.RecomputeThumbnailsAction" defaultConcurrency="2" defaultPartitions="6" name="recomputeThumbnails">
          <policy continueOnFailure="true" delay="1s" maxDelay="10s" maxRetries="3" name="default"/>
        </streamProcessor>
      </extension>